package com.skymobi.cassandra.service;

import java.io.IOException;

import org.apache.cassandra.service.CassandraDaemon;
import org.apache.thrift.transport.TTransportException;

public class EmbeddedCassandraService implements Runnable {

	CassandraDaemon daemon;

	public void init() throws TTransportException, IOException {
		daemon = new CassandraDaemon();
		daemon.init(null);
	}

	@Override
	public void run() {
		daemon.start();
	}

}
